/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package station;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;

/**
 *
 * @author safe
 */
public class NutzdatenListener extends Thread {

    /**
     * wartet auf eingehende verbindungen in linux konsole: java nutzdaten.class
     * ... | java ReadInput. Danach hier in dieser Klasse mir System.in
     * (Scanner) abfangen und verarbeiten.
     */
    BufferedReader br;
    int NUTZDATENLAENGE = 24;

    NutzdatenListener() {
        br = new BufferedReader(new InputStreamReader(System.in));
    }

    @Override
    public void run() {
        //       DataNaechsteNachricht.setReferenceData("123456789012345678901234".getBytes());
        try {
            char[] cbuf = new char[NUTZDATENLAENGE];

            while (true) {
                int read = br.read(cbuf, 0, cbuf.length);
                if (read > 0) {
                    byte[] nutzdatenAry = new String(cbuf).getBytes();
                    DataNaechsteNachricht.setReferenceData(nutzdatenAry);
                } else {
                    sleep(100);
                }
            }
        } catch (IOException ex) {
        } catch (InterruptedException ex) {
        }
    }
}
